//package com.hb.resource.consumer;
//
//import com.hb.resource.constants.KafkaConstants;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.kafka.support.Acknowledgment;
//import org.springframework.stereotype.Component;
//
///**
// *  kafka消费者
// *
// * @author hb
// * @date 2023/04/26
// */
//@Component
//@Slf4j
//public class GupiaoKafKaConsumer {
//
//    /**
//     * 收到信息
//     * 指定消费某一个分区
//     *
//     * @param info  数据信息
//     * @param acknowledgment 手动确认消息
//     */
//    @KafkaListener(id = "",topics = KafkaConstants.GUPIAO_TOPIC, containerFactory = "KafkaListenerContainerFactory",
//            groupId = KafkaConstants.GUPIAO_GROUP_ID)
//    public void receiveInfo(String info, Acknowledgment acknowledgment){
//        try {
//            log.info("收到一条股票消息"+info);
//            //手动提交消息
//            acknowledgment.acknowledge();
//        } catch (Exception e){
//            e.printStackTrace();
//        }
//    }
//
//}
